package com.kele.test.rabbitmq;

import com.rabbitmq.client.DeliverCallback;
import com.rabbitmq.client.Delivery;

import java.io.IOException;

public class DeliverCallbackImpl implements DeliverCallback {
    @Override
    public void handle(String s, Delivery delivery) throws IOException {
        System.out.println(s);
        System.out.println(new String(delivery.getBody()));
    }
}
